package com.example.listener;//package com.example.listener;
//
//import org.springframework.amqp.rabbit.annotation.*;
//import org.springframework.stereotype.Component;
//
//import static com.example.entity.constant.mq.RabbitmqConstant.*;
//
//@Component
////@RequiredArgsConstructor
//public class RabbitmqComsumer {
////    @RabbitHandler
//    @RabbitListener(bindings = @QueueBinding(
//            value = @Queue(name = CANAL_QUEUE,durable = "true"),
//            exchange = @Exchange(name = CANAL_EXCHANGE),
//            key = CANAL_ROUTING_KEY))
//    public void process(String testMessage){
//        System.out.println("++++++++++++++++++++++");
//        System.out.println("testMessage = " + testMessage);
//    }
//}
